import os
from celery import Celery
from django.conf import settings

# 为celery配置环境变量，识别和加载django的配置文件
# 因为worker是脱离django启动的，且依赖其配置
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'p6_0518.settings') # 主应用

# 创建应用
app = Celery('djangoWorker')

# 简单配置
app.conf.broker_url = 'redis://@localhost:6379/5'
app.conf.result_backend = 'redis://:@localhost:6379/6'


# 自动发现任务
app.autodiscover_tasks(settings.INSTALLED_APPS)

